package com.zh.test.mq;

import com.zh.test.bean.Person;
import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.client.producer.DefaultMQProducer;

import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
import java.util.stream.Collectors;
import java.util.stream.Stream;

/**
 * @Author zh
 * @Description  测试 rocketmq生产者
 * @Date 2020/5/14 
 * @Param 
 * @return 
 **/
@Slf4j
public class RocketMqProducer {


    public static void main(String[] args) {
        boolean b =true;
        int num = 0;
       while(b){
           //todo
           target:{
            num++;
            if(num >= 10000000 ){
                break target;
            }
           }
          if(num == 10000000){
              b = false;
          }

       }
       System.out.println(num);
    }
}
